package cn.jobstart.spider.pipeline;


import cn.jobstart.es.service.IResumeEsService;
import cn.jobstart.service.ITalentSubscriptionTaskService;
import cn.jobstart.spider.parsing.IParsing;
import us.codecraft.webmagic.pipeline.Pipeline;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/**
 * @author sunke
 * @version 1.0
 * @Description
 * @date 2023-09-19 15:41
 */
public abstract class AbstractPipline implements Pipeline {

    protected static final ExecutorService executor = Executors.newScheduledThreadPool(10);
    private IResumeEsService resumeEsService;
    private ITalentSubscriptionTaskService talentSubscriptionTaskService;
    private IParsing parsing;

    public IResumeEsService getResumeEsService() {
        return resumeEsService;
    }

    public AbstractPipline setResumeEsService(IResumeEsService resumeEsService) {
        this.resumeEsService = resumeEsService;
        return this;
    }

    public ITalentSubscriptionTaskService getTalentSubscriptionTaskService() {
        return talentSubscriptionTaskService;
    }

    public AbstractPipline setTalentSubscriptionTaskService(ITalentSubscriptionTaskService talentSubscriptionTaskService) {
        this.talentSubscriptionTaskService = talentSubscriptionTaskService;
        return this;
    }

    public IParsing getParsing() {
        return parsing;
    }

    public AbstractPipline setParsing(IParsing parsing) {
        this.parsing = parsing;
        return this;
    }

}
